﻿#include "tcpsocket.h"
#include <QtConcurrent/QtConcurrent>
#include <QHostAddress>
#include <QDebug>
#include "cenum.h"
#define PHONES 20

TcpSocket::TcpSocket(qintptr socketDescriptor, QObject *parent) : //构造函数在主线程执行，lambda在子线程
    QTcpSocket(parent),socketID(socketDescriptor)
{
    this->setSocketDescriptor(socketDescriptor);
    connect(this,&TcpSocket::readyRead,this,&TcpSocket::readData);
    connect(&fuc,&Function::sendDevice,this,&TcpSocket::sendeviceData);  //连接预约信息信号与槽
    dis = connect(this,&TcpSocket::disconnected,
        [&](){
            qDebug() << "disconnect";
            //刷新用户登陆状态
            DBManager::getInstance().updateUserLogonStatus(this->phonenum,false);
            emit sockDisConnect(socketID,this->peerAddress().toString(),this->peerPort(),QThread::currentThread());//发送断开连接的用户信息
            this->deleteLater();
        });
//    connect(&watcher,&QFutureWatcher<QByteArray>::finished,this,&TcpSocket::startNext);
//    connect(&watcher,&QFutureWatcher<QByteArray>::canceled,this,&TcpSocket::startNext);
    qDebug() << "new connect" ;
}

TcpSocket::~TcpSocket()
{

}


void TcpSocket::sentData(const QByteArray &data, const int id)
{
    if(id == socketID)
    {
        write(data);
    }
}

void TcpSocket::disConTcp(int i)
{
    if (i == socketID)
    {
        this->disconnectFromHost();
    }
    else if (i == -1) //-1为全部断开
    {
        disconnect(dis); //先断开连接的信号槽，防止二次析构
        this->disconnectFromHost();
        this->deleteLater();
    }
}





void TcpSocket::readData()
{
    qDebug()<<" readData thread:"<<QThread::currentThread()<<endl;
    QByteArray byt = this->readAll();
    qDebug()<<"oriMsg: "<<byt.toHex()<<endl;
    MsgDatagram msg;
    msg.ip = this->peerAddress().toString();
    msg.port = this->peerPort();
    if(this->handleData(byt,msg))
    {
        qDebug()<<"msg function:"<<msg.function;


        if(CEnum::enumtoString(msg.m_source).toLower() == "surgery")
        {
           int fun = msg.function.toInt()+PHONES;
           msg.function = QString("%1").arg(QString::number(fun));
           qDebug()<<"surgery function:"<<msg.function<<endl;
        }
        QString ori_senddata = fuc.handle(msg);//要发送的原始数据
        qDebug()<<"原始的发送数据："<<ori_senddata<<endl;
        if(!ori_senddata.isEmpty())
            this->sendDataHandle(ori_senddata);
       // disconnect(&fuc,&Function::sendDevice,this,&TcpSocket::sendeviceData);
    }
    else
    {
        qDebug()<<"原始数据有问题";
        //原始数据有错
    }

}

bool TcpSocket::handleData(const QByteArray&originaldata,MsgDatagram &msg)
{
    QTextCodec *txc = QTextCodec::codecForName("GBK");
    if(CRCCheck(originaldata))
    {
        QString NOCRC_Str = txc->toUnicode(originaldata.left(originaldata.length()-2));
        qDebug()<<"length:"<<originaldata.length()<<" "<<"NOCRC_Str:"<<NOCRC_Str<<endl;
        this->infoCorespendent(NOCRC_Str,msg);
    }
    else
    {
        qDebug()<<"CRC 验证失败"<<endl;
        return false;
    }
    return true;
}


quint16 TcpSocket::CRC16(unsigned char *puchMsg, int usDataLen) const
{
    /*高位字节的CRC值*/
        static unsigned char auchCRCHi[] = {
        0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0,
        0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
        0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0,
        0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
        0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1,
        0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41,
        0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1,
        0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
        0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0,
        0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40,
        0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1,
        0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
        0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0,
        0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40,
        0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0,
        0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
        0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0,
        0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
        0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0,
        0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
        0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0,
        0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40,
        0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1,
        0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
        0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0,
        0x80, 0x41,0x00, 0xC1, 0x81,0x40
        };

        /* 低位字节的 CRC 值 */
        static unsigned char auchCRCLo[] = {
        0x00, 0xC0, 0xC1, 0x01, 0xC3, 0x03, 0x02, 0xC2, 0xC6, 0x06,
        0x07, 0xC7, 0x05, 0xC5, 0xC4, 0x04, 0xCC, 0x0C, 0x0D, 0xCD,
        0x0F, 0xCF, 0xCE, 0x0E, 0x0A, 0xCA, 0xCB, 0x0B, 0xC9, 0x09,
        0x08, 0xC8, 0xD8, 0x18, 0x19, 0xD9, 0x1B, 0xDB, 0xDA, 0x1A,
        0x1E, 0xDE, 0xDF, 0x1F, 0xDD, 0x1D, 0x1C, 0xDC, 0x14, 0xD4,
        0xD5, 0x15, 0xD7, 0x17, 0x16, 0xD6, 0xD2, 0x12, 0x13, 0xD3,
        0x11, 0xD1, 0xD0, 0x10, 0xF0, 0x30, 0x31, 0xF1, 0x33, 0xF3,
        0xF2, 0x32, 0x36, 0xF6, 0xF7, 0x37, 0xF5, 0x35, 0x34, 0xF4,
        0x3C, 0xFC, 0xFD, 0x3D, 0xFF, 0x3F, 0x3E, 0xFE, 0xFA, 0x3A,
        0x3B, 0xFB, 0x39, 0xF9, 0xF8, 0x38, 0x28, 0xE8, 0xE9, 0x29,
        0xEB, 0x2B, 0x2A, 0xEA, 0xEE, 0x2E, 0x2F, 0xEF, 0x2D, 0xED,
        0xEC, 0x2C, 0xE4, 0x24, 0x25, 0xE5, 0x27, 0xE7, 0xE6, 0x26,
        0x22, 0xE2, 0xE3, 0x23, 0xE1, 0x21, 0x20, 0xE0, 0xA0, 0x60,
        0x61, 0xA1, 0x63, 0xA3, 0xA2, 0x62, 0x66, 0xA6, 0xA7, 0x67,
        0xA5, 0x65, 0x64, 0xA4, 0x6C, 0xAC, 0xAD, 0x6D, 0xAF, 0x6F,
        0x6E, 0xAE, 0xAA, 0x6A, 0x6B, 0xAB, 0x69, 0xA9, 0xA8, 0x68,
        0x78, 0xB8, 0xB9, 0x79, 0xBB, 0x7B, 0x7A, 0xBA, 0xBE, 0x7E,
        0x7F, 0xBF, 0x7D, 0xBD, 0xBC, 0x7C, 0xB4, 0x74, 0x75, 0xB5,
        0x77, 0xB7, 0xB6, 0x76, 0x72, 0xB2, 0xB3, 0x73, 0xB1, 0x71,
        0x70, 0xB0, 0x50, 0x90, 0x91, 0x51, 0x93, 0x53, 0x52, 0x92,
        0x96, 0x56, 0x57, 0x97, 0x55, 0x95, 0x94, 0x54, 0x9C, 0x5C,
        0x5D, 0x9D, 0x5F, 0x9F, 0x9E, 0x5E, 0x5A, 0x9A, 0x9B, 0x5B,
        0x99, 0x59, 0x58, 0x98, 0x88, 0x48, 0x49, 0x89, 0x4B, 0x8B,
        0x8A, 0x4A, 0x4E, 0x8E, 0x8F, 0x4F, 0x8D, 0x4D, 0x4C, 0x8C,
        0x44, 0x84, 0x85, 0x45, 0x87, 0x47, 0x46, 0x86, 0x82, 0x42,
        0x43, 0x83, 0x41, 0x81, 0x80,0x40
        };
        unsigned char uchCRCHi = 0xFF; // CRC 的高字节初始化
        unsigned char uchCRCLo = 0xFF; // CRC 的低字节初始化
        unsigned uIndex; // CRC 查询表索引
        while (usDataLen--) // 完成整个报文缓冲区
        {
            uIndex = uchCRCLo ^ *puchMsg++; // 计算CRC
            uchCRCLo = uchCRCHi ^ auchCRCHi[uIndex];
            uchCRCHi = auchCRCLo[uIndex];
        }
        return (uchCRCHi << 8 | uchCRCLo);//MODBUS 规定高位在前

}

bool TcpSocket::CRCCheck(const QByteArray &originaldata) const
{
    QByteArray msg_Hex = originaldata.toHex();//trimmed().
qDebug()<<"msg_Hex:"<<msg_Hex<<endl;
    QByteArray msg_byteArray = QByteArray::fromHex(msg_Hex.left(msg_Hex.length()-4));
qDebug()<<"msg_byteArray:"<<msg_byteArray.toHex()<<endl;
    int check_CRC = CRC16(reinterpret_cast<unsigned char*>(msg_byteArray.data()),msg_byteArray.length());
    int self_CRC = originaldata.toHex().right(4).toInt(nullptr,16);
    if(check_CRC == self_CRC)
        return true;
    else
        return false;

}

void TcpSocket::infoCorespendent(QString &noCrCstr, MsgDatagram &msg)
{

    QMap<QString, QString> map;
    QRegularExpression reg1("(?<=\\;).*?(?=\\:)");
    QRegularExpressionMatchIterator iterKey = reg1.globalMatch(noCrCstr);
    QRegularExpression reg2("(?<=\\:).*?(?=\\;)");
    QRegularExpressionMatchIterator iterValue = reg2.globalMatch(noCrCstr);
    while (iterKey.hasNext() && iterValue.hasNext())
        map.insert(iterKey.next().captured(0),iterValue.next().captured(0));
    foreach (QString key, map.keys()) {
       qDebug() << key << ":" << map.value(key);
    }
   msg.m_Head= "7E7E";
   msg.m_source = CEnum::stringToEnum<CEnum::MSG_SOURCE>(map["kind"].toUpper());
   msg.function = map["function"];
   msg.m_user.phoneNum = map["phone"];
   this->phonenum = msg.m_user.phoneNum;
   msg.m_user.password = map["pass"];
   msg.m_user.newPassword = map["newPass"];
   msg.choose = map["choose"],
   msg.m_pressureData.collect_num = map["collectNumber"];
   msg.m_pressureData.value = map["data"];
   if(msg.function=="05"&&msg.m_source == CEnum::MSG_SOURCE::PHONE)
   {
       msg.m_patientInfo.p_name = map["name"];
       msg.m_patientInfo.p_sex =  map["sex"];
       msg.m_patientInfo.p_phonenum = this->phonenum;
       msg.m_patientInfo.p_nation = map["nation"];
       msg.m_patientInfo.p_birthday = map["birth"];
       msg.m_patientInfo.p_age = map["age"].toInt();
       msg.m_patientInfo.p_ID = map["id"];
       msg.m_patientInfo.p_bloodtype = CEnum::stringToEnum<CEnum::PATIENT_BLOOD_TYPE>(map["blood"].left(map["blood"].length()-2).toUpper());
       msg.m_patientInfo.p_diseaseHistory = map["illness"];
       msg.m_patientInfo.p_drugAllergyHistory = map["irritability"];
   }



}


void TcpSocket::sendDataHandle(QString data)
{
    QByteArray byteArray;
    QRegExp reg("[\\x4e00-\\x9fa5]+");
    if(!data.contains(reg))
        byteArray = data.toUtf8().trimmed();
    else
    {
        qDebug()<<"发送数据中包含中文";
        QTextCodec *txc = QTextCodec::codecForName("GBK");
        byteArray = txc->fromUnicode(data);
    }
    qDebug()<<"ByteArray:"<<byteArray<<endl;
    quint16 crc = this->CRC16(reinterpret_cast<unsigned char*>(byteArray.trimmed().data()),byteArray.length());
    qDebug()<<"send data crc:"<<crc<<endl;
    byteArray+= QByteArray::fromHex(QString::number(crc,16).toUtf8());
    qDebug()<<"hexByteArray:"<<endl;


    this->write(byteArray);
}

void TcpSocket::sendDeviceData(TcpSocket *s, QString data)
{
    if(this==s)
        sendDataHandle(data);
}
